import os
from redis.asyncio import Redis, ConnectionPool

# Redis配置

async def sys_cache() -> Redis:
    """
    系统缓存
    :return:  cache 连接池
    """
    # 创建异步Redis连接池
    sys_cache_pool = ConnectionPool.from_url(
        f"redis://{os.getenv('CACHE_HOST', '127.0.0.1')}:{os.getenv('CACHE_PORT', 6379)}",
        db=int(os.getenv('CACHE_DB', 0)),  # 注意：需要转换为整数
        encoding="utf-8",
        decode_responses=True
    )

    # 创建并返回Redis客户端实例
    return Redis(connection_pool=sys_cache_pool)